package com.ruoyi.web.controller.test;

//import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * @author ：hcl
 * @date ：Created in 2023/7/8 09:22
 * @desc ：
 * @modified By：
 */
@Component
public class MQProducerService {
//    @Value("${rocketmq.producer.send-message-timeout}")
//    private Integer messageTimeOut;

    // 建议正常规模项目统一用一个TOPIC
    private static final String topic = "RLT_TEST_TOPIC";

    // 直接注入使用，用于发送消息到broker服务器
//    @Autowired
//    private RocketMQTemplate rocketMQTemplate;
//
//    /**
//     * 普通发送（这里的参数对象User可以随意定义，可以发送个对象，也可以是字符串等）
//     */
//    public void send(String test) {
//        rocketMQTemplate.convertAndSend(topic + ":tag1", test);
////        rocketMQTemplate.send(topic + ":tag1", MessageBuilder.withPayload(user).build()); // 等价于上面一行
//    }
}
